package com.macro.mall.es.controller;

import com.macro.mall.common.api.*;
import com.macro.mall.es.service.EsDocService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotEmpty;
import jakarta.validation.constraints.Size;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import java.util.List;


/**
 * @Author：Minxiao_Hao
 * @Description: es文档管理控制层
 * @name：EsController
 * @Date：2024/10/15 20:38
 */
@RestController
@RequestMapping("/doc")
@Validated
@Api(tags = "es文档管理")
public class EsDocController {
    @Autowired
    private EsDocService esDocService;

    /**
     * 批量添加
     * @param esDocDto 文档信息
     * @return 添加结果
     */
    @ApiOperation(value = "批量添加")
    @PostMapping("/batchSave")
    public CommonResult batchSave(@Validated @RequestBody EsDocDto esDocDto){
        esDocService.batchAdd(esDocDto);
        return CommonResult.successMessage("批量添加成功");
    }

    /**
     * 批量删除
     * @param indexName 索引名称
     * @param ids 多个id
     * @return 删除结果
     */
    @ApiOperation(value = "批量删除")
    @DeleteMapping("/batchDelete")
    public CommonResult batchDelete(@RequestParam("indexName") @NotEmpty(message = "索引名称不能为空") String indexName,
                                    @RequestParam("docIds") @NotBlank(message = "文档id不能为空") @Size(min = 1, message = "文档id列表至少包含一个有效的id") List<String> ids) {
        esDocService.batchDelete(indexName,ids);
        return CommonResult.successMessage("批量删除成功");
    }

    /**
     * 查询接口, 支持分页、排序、查询(公用代码)
     * @param esQuery 查询参数
     * @return 查询结果
     */
    @PostMapping("/basicQuery")
    public CommonResult<EsResult> basicQuery(@RequestBody EsQuery esQuery) {
        //批量添加
        EsResult result = esDocService.basicQuery(esQuery);
        return CommonResult.success(result);
    }

    /**
     * 查询接口, 支持分页、排序、可以支持设置多属性进行全文检索
     * @param esQuery 查询参数
     * @return 查询结果
     */
    @PostMapping("/advancedQuery")
    public CommonResult<EsResult> advancedQuery(@RequestBody EsQuery esQuery) {
        EsResult result = esDocService.advancedQuery(esQuery);
        return CommonResult.success(result);
    }
    /**
     * 根据拼音查询
     *
     * @param searchResult 用户输入的搜索结果
     * @return 匹配的字符串列表
     */
    @PostMapping("/search/pinyin")
    public CommonResult<List<String>> searchByPinyin(@RequestBody SearchResult searchResult) {
        try {
            List<String> result = esDocService.searchByPinyin(searchResult);
            return CommonResult.success(result);
        } catch (Exception e) {
            e.printStackTrace();
            // 这里可以返回一个空列表，或者抛出自定义异常
            return CommonResult.success(null);
        }
    }
}
